package cn.com.utt.unms.job;

import java.sql.Timestamp;
import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import cn.com.utt.unms.mapper.SmsMarketMapper;
import cn.com.utt.unms.mapper.SmsRecordMapper;
import cn.com.utt.unms.pojo.SmsMarketing;
import cn.com.utt.unms.pojo.SmsRecord;

//@Component("smsSendJob")
public class SmsSendJob {
	
//	@Autowired
//	private SmsMarketMapper smsMarketMapper;
//	@Autowired
//	private SmsRecordMapper smsRecordMapper;
//	
//	public void doJob(){
//		// 查询状态为待发送的营销策略
//		List<SmsMarketing> list=smsMarketMapper.querySmsMarketByStatus((byte)2);
//		if(list!=null){
//			String msgId="";
//			String result="";
//			int rrid = 0;
//			Timestamp cur = new Timestamp(System.currentTimeMillis());
//			for (SmsMarketing smsMarketing : list) {
//				// 根据smsmarketing id去sms_record表中查找需要发送的短信
//				List<SmsRecord> records=smsRecordMapper.querySmsRecordByMarketingId(smsMarketing.getId());
//				for (SmsRecord smsRecord : records) {
//					// 发送短信
////					result = smsService.sendSms(smsRecord.getPhone(),smsMarketing.getContext());
//					if(!result.trim().equals("")){
//						if (result.trim().indexOf(",") != -1) {
//							rrid = Integer.parseInt(result.trim().split(",")[0]);
//							msgId = result.trim().split(",")[1];
//						} else {
//							rrid = Integer.parseInt(result.trim());
//						}
//					}
//					
//					if (rrid == 1) {
//						// 短信网关接收到，将msgid保存到smsRecord记录中，并将状态更新为发送成功。
//						smsRecord.setMsgId(msgId);
//						smsRecord.setStatus((byte) 2);
//						smsRecord.setSendTime(cur);
//						smsRecordMapper.updateRecord(smsRecord);
//					} else {
//						// 发送失败，将状态更新为发送失败
//						smsRecord.setStatus((byte) 3);
//						smsRecord.setSendTime(cur);
//						smsRecordMapper.updateRecord(smsRecord);
//					}
//					
//				}
//				// 更新营销策略状态为发送中
//				smsMarketing.setStatus((byte) 3);
//				smsMarketMapper.updateSmsMarketing(smsMarketing);
//			}
//			
//		}
//	}

}
